package org.lwd.datalink.core.runtime;

import org.lwd.datalink.api.task.RecordChunk;
import org.lwd.datalink.utils.FutureCallback;

/**
 * @Author: weidong.lin
 * @Description: Data Chunk Between TaskReader and TaskWriter.
 * @Date: create in 2024/3/25 16:54
 */
public class TaskChunk {
    private RecordChunk recordChunk;
    private FutureCallback callback;

    public TaskChunk(RecordChunk recordChunk, FutureCallback callback) {
        this.recordChunk = recordChunk;
        this.callback = callback;
    }

    public RecordChunk getRecordChunk() {
        return recordChunk;
    }

    public FutureCallback getCallback() {
        return callback;
    }
}
